A B C D E F G H I O S T V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
W
- waitForCommit(Predicate<String>, Duration) - Method in interface com.snowflake.ingest.streaming.SnowflakeStreamingIngestChannel
-
Asynchronously waits for offset token to be committed in the snowflake sever side by checking whether the latest committed offset token meets the commit condition provided by the tokenChecker.
- waitForFlush(Duration) - Method in interface com.snowflake.ingest.streaming.SnowflakeStreamingIngestChannel
-
Asynchronously waits for all buffered data in this channel to be flushed to the Snowflake server side.
- waitForFlush(Duration) - Method in interface com.snowflake.ingest.streaming.SnowflakeStreamingIngestClient
-
Asynchronously waits for all buffered data in all channels managed by this client to be flushed to the Snowflake server side.
All Classes All Packages