public class SnowflakeStreamingServiceConfig
extends java.lang.Object
Constructor and Description |
---|
SnowflakeStreamingServiceConfig(java.util.List<java.lang.String> filesList,
java.lang.String stagingBucketDir,
net.snowflake.ingest.SimpleIngestManager ingestManager)
Constructor to create configuration for streaming write.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
getFilesList()
Getter for a list of staged files which are will be loaded to Snowflake.
|
net.snowflake.ingest.SimpleIngestManager |
getIngestManager()
Getter for ingest manager which serves API to load data in streaming mode and retrieve a report
about loaded data.
|
java.lang.String |
getStagingBucketDir()
Getter for a bucket name with directory where files were staged and waiting for loading.
|
public SnowflakeStreamingServiceConfig(java.util.List<java.lang.String> filesList, java.lang.String stagingBucketDir, net.snowflake.ingest.SimpleIngestManager ingestManager)
filesList
- list of strings of staged files' names.stagingBucketDir
- name of a bucket and directory inside where files are staged and awaits
for being loaded to Snowflake.ingestManager
- instance of SimpleIngestManager
.public net.snowflake.ingest.SimpleIngestManager getIngestManager()
SimpleIngestManager
.public java.util.List<java.lang.String> getFilesList()
public java.lang.String getStagingBucketDir()
gs://mybucket/dir/