snowflake-ingest-java
snowflake-ingest-java copied to clipboard
SNOW-1437884 Flush service supports uploading file to Iceberg tables
Modify flush service to support uploading file to external volume. This PR includes following change:
- Add default parameter
MAX_CLIENT_LAG
for Iceberg mode - Introduce new parameter
DISABLE_CHUNK_ENCRYPTION
to disable chunk encryption in Iceberg mode - Move stage from client level to table level when using Iceberg mode, see:
StreamingIngestExternalVolume.java
- Move stage/volume configure logic to channel level when using Iceberg
- Fix
FlushServiceTest
andStreamingIngestStage
, more test cases is expected