StreamingConfigTask.fromJson constructor

StreamingConfigTask.fromJson(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, item) => core.MapEntry(
                      key,
                      item as core.String,
                    ),
                  )
                : null,
        windmillServiceEndpoint: _json.containsKey('windmillServiceEndpoint')
            ? _json['windmillServiceEndpoint'] as core.String
            : null,
        windmillServicePort: _json.containsKey('windmillServicePort')
            ? _json['windmillServicePort'] as core.String
            : null,
      );