Package | Description |
---|---|
org.apache.paimon.append | |
org.apache.paimon.flink.compact | |
org.apache.paimon.flink.sink | |
org.apache.paimon.flink.source | |
org.apache.paimon.table.sink |
Modifier and Type | Class and Description |
---|---|
class |
MultiTableUnawareAppendCompactionTask
Compaction task for multi table .
|
Modifier and Type | Method and Description |
---|---|
List<UnawareAppendCompactionTask> |
UnawareAppendTableCompactionCoordinator.run() |
Modifier and Type | Method and Description |
---|---|
void |
UnawareBucketCompactor.processElement(UnawareAppendCompactionTask task) |
Modifier and Type | Method and Description |
---|---|
UnawareAppendCompactionTask |
CompactionTaskSimpleSerializer.deserialize(int compactionTaskVersion,
byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.typeutils.TypeSerializer<UnawareAppendCompactionTask> |
CompactionTaskTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable> |
UnawareBucketCompactionSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
Class<UnawareAppendCompactionTask> |
CompactionTaskTypeInfo.getTypeClass() |
Modifier and Type | Method and Description |
---|---|
byte[] |
CompactionTaskSimpleSerializer.serialize(UnawareAppendCompactionTask compactionTask) |
Modifier and Type | Method and Description |
---|---|
void |
AppendBypassCompactWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.types.Either<Committable,UnawareAppendCompactionTask>> element) |
void |
AppendOnlySingleTableCompactionWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<UnawareAppendCompactionTask> element) |
static org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
UnawareBucketCompactionSink.sink(FileStoreTable table,
org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>> |
AppendBypassCoordinateOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>> parameters) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.streaming.api.datastream.DataStreamSource<UnawareAppendCompactionTask> |
BucketUnawareCompactSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
BucketUnawareCompactSource source,
boolean streaming,
String tableIdentifier) |
Modifier and Type | Method and Description |
---|---|
<T extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>>> |
AppendBypassCoordinateOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.types.Either<CommitT,UnawareAppendCompactionTask>> parameters) |
void |
BucketUnawareCompactSource.run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<UnawareAppendCompactionTask> sourceContext) |
Modifier and Type | Method and Description |
---|---|
UnawareAppendCompactionTask |
CompactionTaskSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
List<UnawareAppendCompactionTask> |
CompactionTaskSerializer.deserializeList(int version,
DataInputView view) |
Modifier and Type | Method and Description |
---|---|
byte[] |
CompactionTaskSerializer.serialize(UnawareAppendCompactionTask obj) |
Modifier and Type | Method and Description |
---|---|
void |
CompactionTaskSerializer.serializeList(List<UnawareAppendCompactionTask> list,
DataOutputView view) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.