Packages

package metadata

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. case class StateMetadataInputPartition(checkpointLocation: String) extends InputPartition with Product with Serializable
  2. class StateMetadataPartitionReader extends PartitionReader[InternalRow] with Logging
  3. case class StateMetadataPartitionReaderFactory(hadoopConf: SerializableConfiguration, batchId: Long) extends PartitionReaderFactory with Product with Serializable
  4. class StateMetadataScan extends Scan
  5. class StateMetadataSource extends TableProvider with DataSourceRegister
  6. class StateMetadataTable extends Table with SupportsRead with SupportsMetadataColumns
  7. case class StateMetadataTableEntry(operatorId: Long, operatorName: String, stateStoreName: String, numPartitions: Int, minBatchId: Long, maxBatchId: Long, version: Int, operatorPropertiesJson: String, numColsPrefixKey: Int, stateSchemaFilePaths: List[String]) extends Product with Serializable

Value Members

  1. object StateMetadataTableEntry extends Serializable

Ungrouped