/*
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
/*
* Do not modify this file. This file is generated from the glue-2017-03-31.normal.json service model.
*/
using System;
using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Text;
using System.Xml.Serialization;
using Amazon.Glue.Model;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Transform;
using Amazon.Runtime.Internal.Util;
using ThirdParty.Json.LitJson;
namespace Amazon.Glue.Model.Internal.MarshallTransformations
{
///
/// CodeGenConfigurationNode Marshaller
///
public class CodeGenConfigurationNodeMarshaller : IRequestMarshaller
{
///
/// Unmarshaller the response from the service to the response class.
///
///
///
///
public void Marshall(CodeGenConfigurationNode requestObject, JsonMarshallerContext context)
{
if(requestObject.IsSetAggregate())
{
context.Writer.WritePropertyName("Aggregate");
context.Writer.WriteObjectStart();
var marshaller = AggregateMarshaller.Instance;
marshaller.Marshall(requestObject.Aggregate, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetAmazonRedshiftSource())
{
context.Writer.WritePropertyName("AmazonRedshiftSource");
context.Writer.WriteObjectStart();
var marshaller = AmazonRedshiftSourceMarshaller.Instance;
marshaller.Marshall(requestObject.AmazonRedshiftSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetAmazonRedshiftTarget())
{
context.Writer.WritePropertyName("AmazonRedshiftTarget");
context.Writer.WriteObjectStart();
var marshaller = AmazonRedshiftTargetMarshaller.Instance;
marshaller.Marshall(requestObject.AmazonRedshiftTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetApplyMapping())
{
context.Writer.WritePropertyName("ApplyMapping");
context.Writer.WriteObjectStart();
var marshaller = ApplyMappingMarshaller.Instance;
marshaller.Marshall(requestObject.ApplyMapping, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetAthenaConnectorSource())
{
context.Writer.WritePropertyName("AthenaConnectorSource");
context.Writer.WriteObjectStart();
var marshaller = AthenaConnectorSourceMarshaller.Instance;
marshaller.Marshall(requestObject.AthenaConnectorSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCatalogDeltaSource())
{
context.Writer.WritePropertyName("CatalogDeltaSource");
context.Writer.WriteObjectStart();
var marshaller = CatalogDeltaSourceMarshaller.Instance;
marshaller.Marshall(requestObject.CatalogDeltaSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCatalogHudiSource())
{
context.Writer.WritePropertyName("CatalogHudiSource");
context.Writer.WriteObjectStart();
var marshaller = CatalogHudiSourceMarshaller.Instance;
marshaller.Marshall(requestObject.CatalogHudiSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCatalogKafkaSource())
{
context.Writer.WritePropertyName("CatalogKafkaSource");
context.Writer.WriteObjectStart();
var marshaller = CatalogKafkaSourceMarshaller.Instance;
marshaller.Marshall(requestObject.CatalogKafkaSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCatalogKinesisSource())
{
context.Writer.WritePropertyName("CatalogKinesisSource");
context.Writer.WriteObjectStart();
var marshaller = CatalogKinesisSourceMarshaller.Instance;
marshaller.Marshall(requestObject.CatalogKinesisSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCatalogSource())
{
context.Writer.WritePropertyName("CatalogSource");
context.Writer.WriteObjectStart();
var marshaller = CatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.CatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCatalogTarget())
{
context.Writer.WritePropertyName("CatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = BasicCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.CatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetCustomCode())
{
context.Writer.WritePropertyName("CustomCode");
context.Writer.WriteObjectStart();
var marshaller = CustomCodeMarshaller.Instance;
marshaller.Marshall(requestObject.CustomCode, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDirectJDBCSource())
{
context.Writer.WritePropertyName("DirectJDBCSource");
context.Writer.WriteObjectStart();
var marshaller = DirectJDBCSourceMarshaller.Instance;
marshaller.Marshall(requestObject.DirectJDBCSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDirectKafkaSource())
{
context.Writer.WritePropertyName("DirectKafkaSource");
context.Writer.WriteObjectStart();
var marshaller = DirectKafkaSourceMarshaller.Instance;
marshaller.Marshall(requestObject.DirectKafkaSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDirectKinesisSource())
{
context.Writer.WritePropertyName("DirectKinesisSource");
context.Writer.WriteObjectStart();
var marshaller = DirectKinesisSourceMarshaller.Instance;
marshaller.Marshall(requestObject.DirectKinesisSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDropDuplicates())
{
context.Writer.WritePropertyName("DropDuplicates");
context.Writer.WriteObjectStart();
var marshaller = DropDuplicatesMarshaller.Instance;
marshaller.Marshall(requestObject.DropDuplicates, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDropFields())
{
context.Writer.WritePropertyName("DropFields");
context.Writer.WriteObjectStart();
var marshaller = DropFieldsMarshaller.Instance;
marshaller.Marshall(requestObject.DropFields, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDropNullFields())
{
context.Writer.WritePropertyName("DropNullFields");
context.Writer.WriteObjectStart();
var marshaller = DropNullFieldsMarshaller.Instance;
marshaller.Marshall(requestObject.DropNullFields, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDynamicTransform())
{
context.Writer.WritePropertyName("DynamicTransform");
context.Writer.WriteObjectStart();
var marshaller = DynamicTransformMarshaller.Instance;
marshaller.Marshall(requestObject.DynamicTransform, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetDynamoDBCatalogSource())
{
context.Writer.WritePropertyName("DynamoDBCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = DynamoDBCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.DynamoDBCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetEvaluateDataQuality())
{
context.Writer.WritePropertyName("EvaluateDataQuality");
context.Writer.WriteObjectStart();
var marshaller = EvaluateDataQualityMarshaller.Instance;
marshaller.Marshall(requestObject.EvaluateDataQuality, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetEvaluateDataQualityMultiFrame())
{
context.Writer.WritePropertyName("EvaluateDataQualityMultiFrame");
context.Writer.WriteObjectStart();
var marshaller = EvaluateDataQualityMultiFrameMarshaller.Instance;
marshaller.Marshall(requestObject.EvaluateDataQualityMultiFrame, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetFillMissingValues())
{
context.Writer.WritePropertyName("FillMissingValues");
context.Writer.WriteObjectStart();
var marshaller = FillMissingValuesMarshaller.Instance;
marshaller.Marshall(requestObject.FillMissingValues, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetFilter())
{
context.Writer.WritePropertyName("Filter");
context.Writer.WriteObjectStart();
var marshaller = FilterMarshaller.Instance;
marshaller.Marshall(requestObject.Filter, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetGovernedCatalogSource())
{
context.Writer.WritePropertyName("GovernedCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = GovernedCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.GovernedCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetGovernedCatalogTarget())
{
context.Writer.WritePropertyName("GovernedCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = GovernedCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.GovernedCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetJDBCConnectorSource())
{
context.Writer.WritePropertyName("JDBCConnectorSource");
context.Writer.WriteObjectStart();
var marshaller = JDBCConnectorSourceMarshaller.Instance;
marshaller.Marshall(requestObject.JDBCConnectorSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetJDBCConnectorTarget())
{
context.Writer.WritePropertyName("JDBCConnectorTarget");
context.Writer.WriteObjectStart();
var marshaller = JDBCConnectorTargetMarshaller.Instance;
marshaller.Marshall(requestObject.JDBCConnectorTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetJoin())
{
context.Writer.WritePropertyName("Join");
context.Writer.WriteObjectStart();
var marshaller = JoinMarshaller.Instance;
marshaller.Marshall(requestObject.Join, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetMerge())
{
context.Writer.WritePropertyName("Merge");
context.Writer.WriteObjectStart();
var marshaller = MergeMarshaller.Instance;
marshaller.Marshall(requestObject.Merge, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetMicrosoftSQLServerCatalogSource())
{
context.Writer.WritePropertyName("MicrosoftSQLServerCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = MicrosoftSQLServerCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.MicrosoftSQLServerCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetMicrosoftSQLServerCatalogTarget())
{
context.Writer.WritePropertyName("MicrosoftSQLServerCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = MicrosoftSQLServerCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.MicrosoftSQLServerCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetMySQLCatalogSource())
{
context.Writer.WritePropertyName("MySQLCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = MySQLCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.MySQLCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetMySQLCatalogTarget())
{
context.Writer.WritePropertyName("MySQLCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = MySQLCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.MySQLCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetOracleSQLCatalogSource())
{
context.Writer.WritePropertyName("OracleSQLCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = OracleSQLCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.OracleSQLCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetOracleSQLCatalogTarget())
{
context.Writer.WritePropertyName("OracleSQLCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = OracleSQLCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.OracleSQLCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetPIIDetection())
{
context.Writer.WritePropertyName("PIIDetection");
context.Writer.WriteObjectStart();
var marshaller = PIIDetectionMarshaller.Instance;
marshaller.Marshall(requestObject.PIIDetection, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetPostgreSQLCatalogSource())
{
context.Writer.WritePropertyName("PostgreSQLCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = PostgreSQLCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.PostgreSQLCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetPostgreSQLCatalogTarget())
{
context.Writer.WritePropertyName("PostgreSQLCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = PostgreSQLCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.PostgreSQLCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetRecipe())
{
context.Writer.WritePropertyName("Recipe");
context.Writer.WriteObjectStart();
var marshaller = RecipeMarshaller.Instance;
marshaller.Marshall(requestObject.Recipe, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetRedshiftSource())
{
context.Writer.WritePropertyName("RedshiftSource");
context.Writer.WriteObjectStart();
var marshaller = RedshiftSourceMarshaller.Instance;
marshaller.Marshall(requestObject.RedshiftSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetRedshiftTarget())
{
context.Writer.WritePropertyName("RedshiftTarget");
context.Writer.WriteObjectStart();
var marshaller = RedshiftTargetMarshaller.Instance;
marshaller.Marshall(requestObject.RedshiftTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetRelationalCatalogSource())
{
context.Writer.WritePropertyName("RelationalCatalogSource");
context.Writer.WriteObjectStart();
var marshaller = RelationalCatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.RelationalCatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetRenameField())
{
context.Writer.WritePropertyName("RenameField");
context.Writer.WriteObjectStart();
var marshaller = RenameFieldMarshaller.Instance;
marshaller.Marshall(requestObject.RenameField, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3CatalogDeltaSource())
{
context.Writer.WritePropertyName("S3CatalogDeltaSource");
context.Writer.WriteObjectStart();
var marshaller = S3CatalogDeltaSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3CatalogDeltaSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3CatalogHudiSource())
{
context.Writer.WritePropertyName("S3CatalogHudiSource");
context.Writer.WriteObjectStart();
var marshaller = S3CatalogHudiSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3CatalogHudiSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3CatalogSource())
{
context.Writer.WritePropertyName("S3CatalogSource");
context.Writer.WriteObjectStart();
var marshaller = S3CatalogSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3CatalogSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3CatalogTarget())
{
context.Writer.WritePropertyName("S3CatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = S3CatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3CatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3CsvSource())
{
context.Writer.WritePropertyName("S3CsvSource");
context.Writer.WriteObjectStart();
var marshaller = S3CsvSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3CsvSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3DeltaCatalogTarget())
{
context.Writer.WritePropertyName("S3DeltaCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = S3DeltaCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3DeltaCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3DeltaDirectTarget())
{
context.Writer.WritePropertyName("S3DeltaDirectTarget");
context.Writer.WriteObjectStart();
var marshaller = S3DeltaDirectTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3DeltaDirectTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3DeltaSource())
{
context.Writer.WritePropertyName("S3DeltaSource");
context.Writer.WriteObjectStart();
var marshaller = S3DeltaSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3DeltaSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3DirectTarget())
{
context.Writer.WritePropertyName("S3DirectTarget");
context.Writer.WriteObjectStart();
var marshaller = S3DirectTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3DirectTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3GlueParquetTarget())
{
context.Writer.WritePropertyName("S3GlueParquetTarget");
context.Writer.WriteObjectStart();
var marshaller = S3GlueParquetTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3GlueParquetTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3HudiCatalogTarget())
{
context.Writer.WritePropertyName("S3HudiCatalogTarget");
context.Writer.WriteObjectStart();
var marshaller = S3HudiCatalogTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3HudiCatalogTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3HudiDirectTarget())
{
context.Writer.WritePropertyName("S3HudiDirectTarget");
context.Writer.WriteObjectStart();
var marshaller = S3HudiDirectTargetMarshaller.Instance;
marshaller.Marshall(requestObject.S3HudiDirectTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3HudiSource())
{
context.Writer.WritePropertyName("S3HudiSource");
context.Writer.WriteObjectStart();
var marshaller = S3HudiSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3HudiSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3JsonSource())
{
context.Writer.WritePropertyName("S3JsonSource");
context.Writer.WriteObjectStart();
var marshaller = S3JsonSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3JsonSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetS3ParquetSource())
{
context.Writer.WritePropertyName("S3ParquetSource");
context.Writer.WriteObjectStart();
var marshaller = S3ParquetSourceMarshaller.Instance;
marshaller.Marshall(requestObject.S3ParquetSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSelectFields())
{
context.Writer.WritePropertyName("SelectFields");
context.Writer.WriteObjectStart();
var marshaller = SelectFieldsMarshaller.Instance;
marshaller.Marshall(requestObject.SelectFields, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSelectFromCollection())
{
context.Writer.WritePropertyName("SelectFromCollection");
context.Writer.WriteObjectStart();
var marshaller = SelectFromCollectionMarshaller.Instance;
marshaller.Marshall(requestObject.SelectFromCollection, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSnowflakeSource())
{
context.Writer.WritePropertyName("SnowflakeSource");
context.Writer.WriteObjectStart();
var marshaller = SnowflakeSourceMarshaller.Instance;
marshaller.Marshall(requestObject.SnowflakeSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSnowflakeTarget())
{
context.Writer.WritePropertyName("SnowflakeTarget");
context.Writer.WriteObjectStart();
var marshaller = SnowflakeTargetMarshaller.Instance;
marshaller.Marshall(requestObject.SnowflakeTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSparkConnectorSource())
{
context.Writer.WritePropertyName("SparkConnectorSource");
context.Writer.WriteObjectStart();
var marshaller = SparkConnectorSourceMarshaller.Instance;
marshaller.Marshall(requestObject.SparkConnectorSource, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSparkConnectorTarget())
{
context.Writer.WritePropertyName("SparkConnectorTarget");
context.Writer.WriteObjectStart();
var marshaller = SparkConnectorTargetMarshaller.Instance;
marshaller.Marshall(requestObject.SparkConnectorTarget, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSparkSQL())
{
context.Writer.WritePropertyName("SparkSQL");
context.Writer.WriteObjectStart();
var marshaller = SparkSQLMarshaller.Instance;
marshaller.Marshall(requestObject.SparkSQL, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSpigot())
{
context.Writer.WritePropertyName("Spigot");
context.Writer.WriteObjectStart();
var marshaller = SpigotMarshaller.Instance;
marshaller.Marshall(requestObject.Spigot, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetSplitFields())
{
context.Writer.WritePropertyName("SplitFields");
context.Writer.WriteObjectStart();
var marshaller = SplitFieldsMarshaller.Instance;
marshaller.Marshall(requestObject.SplitFields, context);
context.Writer.WriteObjectEnd();
}
if(requestObject.IsSetUnion())
{
context.Writer.WritePropertyName("Union");
context.Writer.WriteObjectStart();
var marshaller = UnionMarshaller.Instance;
marshaller.Marshall(requestObject.Union, context);
context.Writer.WriteObjectEnd();
}
}
///
/// Singleton Marshaller.
///
public readonly static CodeGenConfigurationNodeMarshaller Instance = new CodeGenConfigurationNodeMarshaller();
}
}