| Package | Description |
|---|---|
| org.apache.paimon.flink.sink |
| Modifier and Type | Method and Description |
|---|---|
List<StoreSinkWriteState.StateValue> |
StoreSinkWriteState.get(String tableName,
String key) |
List<StoreSinkWriteState.StateValue> |
NoopStoreSinkWriteState.get(String tableName,
String key) |
List<StoreSinkWriteState.StateValue> |
StoreSinkWriteStateImpl.get(String tableName,
String key) |
| Modifier and Type | Method and Description |
|---|---|
void |
StoreSinkWriteState.put(String tableName,
String key,
List<StoreSinkWriteState.StateValue> stateValues) |
void |
NoopStoreSinkWriteState.put(String tableName,
String key,
List<StoreSinkWriteState.StateValue> stateValues) |
void |
StoreSinkWriteStateImpl.put(String tableName,
String key,
List<StoreSinkWriteState.StateValue> stateValues) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.