public class SinkRecord extends Object
Constructor and Description |
---|
SinkRecord(BinaryRow partition,
int bucket,
BinaryRow primaryKey,
InternalRow row) |
Modifier and Type | Method and Description |
---|---|
int |
bucket() |
BinaryRow |
partition() |
BinaryRow |
primaryKey() |
InternalRow |
row() |
public SinkRecord(BinaryRow partition, int bucket, BinaryRow primaryKey, InternalRow row)
public BinaryRow partition()
public int bucket()
public BinaryRow primaryKey()
public InternalRow row()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.