구성

구성 (Configuration)

기본적으로 Table & SQL API는 허용 가능한 성능으로 정확한 결과를 생성하도록 사전 구성되어 있습니다.

테이블 프로그램의 요구 사항에 따라 최적화를 위해 특정 파라미터를 조정해야 할 수 있습니다. 예를 들어 무한 스트리밍 프로그램은 필요한 상태 크기가 상한을 갖도록 보장해야 할 수 있습니다(스트리밍 개념 참고).

출처: 문서

본문

개요 (Overview)

TableEnvironment를 인스턴스화할 때 EnvironmentSettings로 Configuration 객체를 전달해 현재 세션에 원하는 구성을 전달할 수 있습니다.

또한 모든 테이블 환경에서 TableConfig가 현재 세션을 구성하는 옵션을 제공합니다.

공통 또는 중요한 구성 옵션에 대해 TableConfig는 상세한 인라인 문서가 있는 getter와 setter 메서드를 제공합니다.

더 고급 구성의 경우 사용자는 기본 키-값 맵에 직접 접근할 수 있습니다. 다음 섹션들은 Flink Table & SQL API 프로그램을 조정하는 데 사용할 수 있는 모든 옵션을 나열합니다.

주의: 옵션은 연산 수행 시 서로 다른 시점에 읽히기 때문에, 테이블 환경을 인스턴스화한 직후 구성 옵션을 일찍 설정하는 것을 권장합니다.

Java

// instantiate table environment
Configuration configuration = new Configuration();
// set low-level key-value options
configuration.setString("table.exec.mini-batch.enabled", "true");
configuration.setString("table.exec.mini-batch.allow-latency", "5 s");
configuration.setString("table.exec.mini-batch.size", "5000");
EnvironmentSettings settings = EnvironmentSettings.newInstance()
        .inStreamingMode().withConfiguration(configuration).build();
TableEnvironment tEnv = TableEnvironment.create(settings);

// access flink configuration after table environment instantiation
TableConfig tableConfig = tEnv.getConfig();
// set low-level key-value options
tableConfig.set("table.exec.mini-batch.enabled", "true");
tableConfig.set("table.exec.mini-batch.allow-latency", "5 s");
tableConfig.set("table.exec.mini-batch.size", "5000");

Scala

// instantiate table environment
val configuration = new Configuration;
// set low-level key-value options
configuration.setString("table.exec.mini-batch.enabled", "true")
configuration.setString("table.exec.mini-batch.allow-latency", "5 s")
configuration.setString("table.exec.mini-batch.size", "5000")
val settings = EnvironmentSettings.newInstance
  .inStreamingMode.withConfiguration(configuration).build
val tEnv: TableEnvironment = TableEnvironment.create(settings)

// access flink configuration after table environment instantiation
val tableConfig = tEnv.getConfig()
// set low-level key-value options
tableConfig.set("table.exec.mini-batch.enabled", "true")
tableConfig.set("table.exec.mini-batch.allow-latency", "5 s")
tableConfig.set("table.exec.mini-batch.size", "5000")

Python

# instantiate table environment
configuration = Configuration()
configuration.set("table.exec.mini-batch.enabled", "true")
configuration.set("table.exec.mini-batch.allow-latency", "5 s")
configuration.set("table.exec.mini-batch.size", "5000")
settings = EnvironmentSettings.new_instance() \
...     .in_streaming_mode() \
...     .with_configuration(configuration) \
...     .build()

t_env = TableEnvironment.create(settings)

# access flink configuration after table environment instantiation
table_config = t_env.get_config()
# set low-level key-value options
table_config.set("table.exec.mini-batch.enabled", "true")
table_config.set("table.exec.mini-batch.allow-latency", "5 s")
table_config.set("table.exec.mini-batch.size", "5000")

SQL CLI

Flink SQL> SET 'table.exec.mini-batch.enabled' = 'true';
Flink SQL> SET 'table.exec.mini-batch.allow-latency' = '5s';
Flink SQL> SET 'table.exec.mini-batch.size' = '5000';

참고: 다음의 모든 구성 옵션은 Flink 구성 파일에 전역으로 설정할 수도 있으며, 이후 애플리케이션에서 EnvironmentSettings를 통해(또는 TableEnvironment 인스턴스화 전에) 또는 TableEnvironment의 TableConfig를 통해 재정의할 수 있습니다.

실행 옵션 (Execution Options)

다음 옵션은 쿼리 실행의 성능을 튜닝하는 데 사용할 수 있습니다.

옵티마이저 옵션 (Optimizer Options)

다음 옵션은 더 나은 실행 계획을 얻기 위해 쿼리 옵티마이저의 동작을 조정하는 데 사용할 수 있습니다.

테이블 옵션 (Table Options)

다음 옵션은 테이블 플래너의 동작을 조정하는 데 사용할 수 있습니다.

구체화 테이블 옵션 (Materialized Table Options)

다음 옵션은 구체화 테이블(materialized table)의 동작을 조정하는 데 사용할 수 있습니다.

SQL Client 옵션 (SQL Client Options)

다음 옵션은 sql client의 동작을 조정하는 데 사용할 수 있습니다.

더 알아보기 (Learn more)

• Streaming Concepts
• Query Configuration
• Table API