Package | Description |
---|---|
org.apache.paimon.flink.sink | |
org.apache.paimon.flink.source | |
org.apache.paimon.flink.source.operator | |
org.apache.paimon.table.sink |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.common.typeutils.TypeSerializer<MultiTableUnawareAppendCompactionTask> |
MultiTableCompactionTaskTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig) |
Class<MultiTableUnawareAppendCompactionTask> |
MultiTableCompactionTaskTypeInfo.getTypeClass() |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.api.datastream.DataStream<MultiTableCommittable> |
CombinedTableCompactorSink.doWrite(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> awareBucketTableSource,
org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> unawareBucketTableSource,
String commitUser) |
void |
AppendOnlyMultiTableCompactionWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableUnawareAppendCompactionTask> element) |
org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
CombinedTableCompactorSink.sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> awareBucketTableSource,
org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> unawareBucketTableSource) |
org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
CombinedTableCompactorSink.sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> awareBucketTableSource,
org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> unawareBucketTableSource,
String initialCommitUser) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> |
CombinedTableCompactorSourceBuilder.buildForUnawareBucketsTableSource() |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> |
CombinedUnawareBatchSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String name,
Catalog.Loader catalogLoader,
Pattern includingPattern,
Pattern excludingPattern,
Pattern databasePattern,
java.time.Duration partitionIdleTime) |
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask> |
CombinedUnawareStreamingSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String name,
Catalog.Loader catalogLoader,
Pattern includingPattern,
Pattern excludingPattern,
Pattern databasePattern,
long monitorInterval) |
Modifier and Type | Method and Description |
---|---|
void |
MultiUnawareTablesReadOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<MultiTableUnawareAppendCompactionTask> record) |
Modifier and Type | Method and Description |
---|---|
MultiTableUnawareAppendCompactionTask |
MultiTableCompactionTaskSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
List<MultiTableUnawareAppendCompactionTask> |
MultiTableCompactionTaskSerializer.deserializeList(int version,
DataInputView view) |
Modifier and Type | Method and Description |
---|---|
byte[] |
MultiTableCompactionTaskSerializer.serialize(MultiTableUnawareAppendCompactionTask task) |
Modifier and Type | Method and Description |
---|---|
void |
MultiTableCompactionTaskSerializer.serializeList(List<MultiTableUnawareAppendCompactionTask> list,
DataOutputView view) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.