本文整理了Java中cz.seznam.euphoria.core.client.flow.Flow.getSettings()方法的一些代码示例，展示了Flow.getSettings()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Flow.getSettings()方法的具体详情如下：
包路径：cz.seznam.euphoria.core.client.flow.Flow
类名称：Flow
方法名：getSettings

Flow.getSettings介绍

暂无

代码示例

代码示例来源：origin: seznam/euphoria

ExecutionContext context = new ExecutionContext(flow.getSettings());

代码示例来源：origin: seznam/euphoria

ExecutionContext context = new ExecutionContext(flow.getSettings());

代码示例来源：origin: seznam/euphoria

onContextCreationFns.forEach(c -> c.accept(environment));
Settings settings = flow.getSettings();

代码示例来源：origin: seznam/euphoria

final Settings settings = flow.getSettings();
if (desiredSplitSize != -1) {
 settings.setLong(InputTranslator.DESIRED_SPLIT_SIZE, desiredSplitSize);

代码示例来源：origin: seznam/euphoria

@SuppressWarnings("unchecked")
private void run() {
 final Dataset<Cell> ds;
 flow.getSettings().setInt(
   "euphoria.flink.batch.list-storage.max-memory-elements", 100);
 switch (input.getScheme()) {

代码示例来源：origin: seznam/euphoria

new SparkFlowTranslator(sparkContext, flow.getSettings(), mockedFactory, new HashMap<>());
translator.translateInto(flow, StorageLevel.MEMORY_ONLY());