Delen via


StreamInputProperties Class

Definition

The properties that are associated with an input containing stream data.

public class StreamInputProperties : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputProperties, System.ClientModel.Primitives.IJsonModel<Azure.ResourceManager.StreamAnalytics.Models.StreamInputProperties>, System.ClientModel.Primitives.IPersistableModel<Azure.ResourceManager.StreamAnalytics.Models.StreamInputProperties>
public class StreamInputProperties : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputProperties
type StreamInputProperties = class
    inherit StreamingJobInputProperties
    interface IJsonModel<StreamInputProperties>
    interface IPersistableModel<StreamInputProperties>
type StreamInputProperties = class
    inherit StreamingJobInputProperties
Public Class StreamInputProperties
Inherits StreamingJobInputProperties
Implements IJsonModel(Of StreamInputProperties), IPersistableModel(Of StreamInputProperties)
Public Class StreamInputProperties
Inherits StreamingJobInputProperties
Inheritance
StreamInputProperties
Implements

Constructors

StreamInputProperties()

Initializes a new instance of StreamInputProperties.

Properties

CompressionType

Indicates the type of compression that the input uses. Required on PUT (CreateOrReplace) requests.

(Inherited from StreamingJobInputProperties)
Datasource

Describes an input data source that contains stream data. Required on PUT (CreateOrReplace) requests. Please note StreamInputDataSource is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. The available derived classes include GatewayMessageBusStreamInputDataSource, IoTHubStreamInputDataSource, EventGridStreamInputDataSource, EventHubV2StreamInputDataSource, EventHubStreamInputDataSource, BlobStreamInputDataSource and RawStreamInputDataSource.

DiagnosticsConditions

A collection of zero or more conditions applicable to the resource, or to the job overall, that warrant customer attention.

(Inherited from StreamingJobInputProperties)
ETag

The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.

(Inherited from StreamingJobInputProperties)
PartitionKey

partitionKey Describes a key in the input data which is used for partitioning the input data.

(Inherited from StreamingJobInputProperties)
Serialization

Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. Please note StreamAnalyticsDataSerialization is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. The available derived classes include AvroFormatSerialization, CsvFormatSerialization, CustomClrFormatSerialization, JsonFormatSerialization and ParquetFormatSerialization.

(Inherited from StreamingJobInputProperties)
WatermarkMode

The input watermark mode.

(Inherited from StreamingJobInputProperties)

Methods

JsonModelWriteCore(Utf8JsonWriter, ModelReaderWriterOptions)

Explicit Interface Implementations

IJsonModel<StreamingJobInputProperties>.Create(Utf8JsonReader, ModelReaderWriterOptions)

Reads one JSON value (including objects or arrays) from the provided reader and converts it to a model.

(Inherited from StreamingJobInputProperties)
IJsonModel<StreamingJobInputProperties>.Write(Utf8JsonWriter, ModelReaderWriterOptions)

Writes the model to the provided Utf8JsonWriter.

(Inherited from StreamingJobInputProperties)
IJsonModel<StreamInputProperties>.Create(Utf8JsonReader, ModelReaderWriterOptions)

Reads one JSON value (including objects or arrays) from the provided reader and converts it to a model.

IJsonModel<StreamInputProperties>.Write(Utf8JsonWriter, ModelReaderWriterOptions)

Writes the model to the provided Utf8JsonWriter.

IPersistableModel<StreamingJobInputProperties>.Create(BinaryData, ModelReaderWriterOptions)

Converts the provided BinaryData into a model.

(Inherited from StreamingJobInputProperties)
IPersistableModel<StreamingJobInputProperties>.GetFormatFromOptions(ModelReaderWriterOptions)

Gets the data interchange format (JSON, Xml, etc) that the model uses when communicating with the service.

(Inherited from StreamingJobInputProperties)
IPersistableModel<StreamingJobInputProperties>.Write(ModelReaderWriterOptions)

Writes the model into a BinaryData.

(Inherited from StreamingJobInputProperties)
IPersistableModel<StreamInputProperties>.Create(BinaryData, ModelReaderWriterOptions)

Converts the provided BinaryData into a model.

IPersistableModel<StreamInputProperties>.GetFormatFromOptions(ModelReaderWriterOptions)

Gets the data interchange format (JSON, Xml, etc) that the model uses when communicating with the service.

IPersistableModel<StreamInputProperties>.Write(ModelReaderWriterOptions)

Writes the model into a BinaryData.

Applies to