class JsonBucketMetadata[K1, K2] extends BucketMetadata[K1, K2, TableRow]
org.apache.beam.sdk.extensions.smb.BucketMetadata for BigQuery TableRow JSON
records.
- Source
- JsonBucketMetadata.java
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- JsonBucketMetadata
- BucketMetadata
- HasDisplayData
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new JsonBucketMetadata(version: Int, numBuckets: Int, numShards: Int, keyClassPrimary: Class[K1], keyField: String, keyClassSecondary: Class[K2], keyFieldSecondary: String, hashType: HashType, filenamePrefix: String)
- new JsonBucketMetadata(numBuckets: Int, numShards: Int, keyClassPrimary: Class[K1], keyField: String, keyClassSecondary: Class[K2], keyFieldSecondary: String, hashType: HashType, filenamePrefix: String)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def coderOverrides(): Map[Class[_ <: AnyRef], Coder[_ <: AnyRef]]
- Definition Classes
- BucketMetadata
- Annotations
- @JsonIgnore()
- def compatibleMetadataTypes(): Set[Class[_ <: BucketMetadata]]
- Definition Classes
- BucketMetadata
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def extractKeyPrimary(value: TableRow): K1
- Definition Classes
- JsonBucketMetadata → BucketMetadata
- Annotations
- @Override()
- def extractKeySecondary(value: TableRow): K2
- Definition Classes
- JsonBucketMetadata → BucketMetadata
- Annotations
- @Override()
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def getFilenamePrefix(): String
- Definition Classes
- BucketMetadata
- def getHashType(): HashType
- Definition Classes
- BucketMetadata
- def getKeyClass(): Class[K1]
- Definition Classes
- BucketMetadata
- def getKeyClassSecondary(): Class[K2]
- Definition Classes
- BucketMetadata
- def getKeyCoder(): Coder[K1]
- Definition Classes
- BucketMetadata
- Annotations
- @JsonIgnore()
- def getKeyCoderSecondary(): Coder[K2]
- Definition Classes
- BucketMetadata
- Annotations
- @JsonIgnore()
- def getNumBuckets(): Int
- Definition Classes
- BucketMetadata
- def getNumShards(): Int
- Definition Classes
- BucketMetadata
- def getVersion(): Int
- Definition Classes
- BucketMetadata
- def hasSecondaryKey(): Boolean
- Definition Classes
- BucketMetadata
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isPartitionCompatibleForPrimaryAndSecondaryKey(other: BucketMetadata): Boolean
- Definition Classes
- BucketMetadata
- def isPartitionCompatibleForPrimaryKey(other: BucketMetadata): Boolean
- Definition Classes
- BucketMetadata
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def populateDisplayData(builder: Builder): Unit
- Definition Classes
- JsonBucketMetadata → BucketMetadata → HasDisplayData
- Annotations
- @Override()
- def primaryAndSecondaryComparableKeyBytes(value: TableRow): ComparableKeyBytes
- Definition Classes
- BucketMetadata
- def primaryComparableKeyBytes(value: TableRow): ComparableKeyBytes
- Definition Classes
- BucketMetadata
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- BucketMetadata → AnyRef → Any
- Annotations
- @Override()
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])