Package org.apache.beam.sdk.io.snowflake

Class SnowflakeSchemaTransformUtils

java.lang.Object

org.apache.beam.sdk.io.snowflake.SnowflakeSchemaTransformUtils

public class SnowflakeSchemaTransformUtils
extends Object

Utilities shared by Snowflake schema transform providers.

Constructor Summary

Constructors

Constructor	Description
SnowflakeSchemaTransformUtils()

Method Summary

Modifier and Type	Method	Description
static SnowflakeIO.DataSourceConfiguration	createDataSourceConfiguration(String serverName, String username, String password, String oauthToken, String privateKey, String privateKeyPassphrase, String database, String snowflakeSchema, String warehouse, String role)
static boolean	isNotEmpty(String value)
static CreateDisposition	parseCreateDisposition(String value)
static StreamingLogLevel	parseStreamingLogLevel(String value)
static WriteDisposition	parseWriteDisposition(String value)
static Object	toBeamValue(String value, Schema.Field field)
static Row	toRow(String[] parts, Schema schema)
static SnowflakeColumn	toSnowflakeColumn(Schema.Field field)
static SnowflakeDataType	toSnowflakeDataType(Schema.Field field)
static SnowflakeTableSchema	toSnowflakeTableSchema(Schema schema)
static IllegalArgumentException	unsupportedFieldType(Schema.Field field, String details)
static void	validateAuthentication(String username, String password, String oauthToken, String privateKey, String privateKeyPassphrase)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SnowflakeSchemaTransformUtils

public SnowflakeSchemaTransformUtils()

Method Details

createDataSourceConfiguration

public static SnowflakeIO.DataSourceConfiguration createDataSourceConfiguration(String serverName,
 @Nullable
 String username,
 @Nullable
 String password,
 @Nullable
 String oauthToken,
 @Nullable
 String privateKey,
 @Nullable
 String privateKeyPassphrase,
 String database,
 String snowflakeSchema,
 @Nullable
 String warehouse,
 @Nullable
 String role)

validateAuthentication

public static void validateAuthentication(@Nullable
 String username,
 @Nullable
 String password,
 @Nullable
 String oauthToken,
 @Nullable
 String privateKey,
 @Nullable
 String privateKeyPassphrase)

isNotEmpty

@EnsuresNonNullIf(expression="#1",
                  result=true)
public static boolean isNotEmpty(@Nullable
 String value)

parseStreamingLogLevel

public static StreamingLogLevel parseStreamingLogLevel(String value)

parseCreateDisposition

public static CreateDisposition parseCreateDisposition(String value)

parseWriteDisposition

public static WriteDisposition parseWriteDisposition(String value)

toSnowflakeTableSchema

public static SnowflakeTableSchema toSnowflakeTableSchema(Schema schema)

toSnowflakeColumn

public static SnowflakeColumn toSnowflakeColumn(Schema.Field field)

toRow

public static Row toRow(String[] parts,
 Schema schema)

toBeamValue

@Nullable
public static Object toBeamValue(String value,
 Schema.Field field)

toSnowflakeDataType

public static SnowflakeDataType toSnowflakeDataType(Schema.Field field)

unsupportedFieldType

public static IllegalArgumentException unsupportedFieldType(Schema.Field field,
 @Nullable
 String details)