StreamingConfigTask.fromJson constructor

StreamingConfigTask.fromJson(
  1. Map json_
)

Implementation

StreamingConfigTask.fromJson(core.Map json_)
    : this(
        commitStreamChunkSizeBytes:
            json_.containsKey('commitStreamChunkSizeBytes')
                ? json_['commitStreamChunkSizeBytes'] as core.String
                : null,
        getDataStreamChunkSizeBytes:
            json_.containsKey('getDataStreamChunkSizeBytes')
                ? json_['getDataStreamChunkSizeBytes'] as core.String
                : null,
        maxWorkItemCommitBytes: json_.containsKey('maxWorkItemCommitBytes')
            ? json_['maxWorkItemCommitBytes'] as core.String
            : null,
        streamingComputationConfigs:
            json_.containsKey('streamingComputationConfigs')
                ? (json_['streamingComputationConfigs'] as core.List)
                    .map((value) => StreamingComputationConfig.fromJson(
                        value as core.Map<core.String, core.dynamic>))
                    .toList()
                : null,
        userStepToStateFamilyNameMap:
            json_.containsKey('userStepToStateFamilyNameMap')
                ? (json_['userStepToStateFamilyNameMap']
                        as core.Map<core.String, core.dynamic>)
                    .map(
                    (key, value) => core.MapEntry(
                      key,
                      value as core.String,
                    ),
                  )
                : null,
        windmillServiceEndpoint: json_.containsKey('windmillServiceEndpoint')
            ? json_['windmillServiceEndpoint'] as core.String
            : null,
        windmillServicePort: json_.containsKey('windmillServicePort')
            ? json_['windmillServicePort'] as core.String
            : null,
      );