Class JsonExporter
Component that writes messages to a multi-stream JSON store.
Inherited Members
Namespace: Microsoft.Psi.Data.Json
Assembly: Microsoft.Psi.Data.dll
Syntax
public class JsonExporter : Subpipeline, ISourceComponent
Constructors
View SourceJsonExporter(Pipeline, String, JsonStoreWriter)
Initializes a new instance of the JsonExporter class.
Declaration
protected JsonExporter(Pipeline pipeline, string name, JsonStoreWriter writer)
Parameters
Type | Name | Description |
---|---|---|
Pipeline | pipeline | The pipeline to add the component to. |
String | name | The name of the application that generated the persisted files, or the root name of the files. |
JsonStoreWriter | writer | The underlying store writer. |
JsonExporter(Pipeline, String, String, Boolean)
Initializes a new instance of the JsonExporter class.
Declaration
public JsonExporter(Pipeline pipeline, string name, string path, bool createSubdirectory = true)
Parameters
Type | Name | Description |
---|---|---|
Pipeline | pipeline | The pipeline to add the component to. |
String | name | The name of the application that generated the persisted files, or the root name of the files. |
String | path | The directory in which the main persisted file resides or will reside, or null to create a volatile data store. |
System.Boolean | createSubdirectory | If true, a numbered sub-directory is created for this store. |
Properties
View SourceName
Gets the name of the store being written to.
Declaration
public string Name { get; }
Property Value
Type | Description |
---|---|
String |
Path
Gets the path to the store being written to if the store is persisted to disk, or null if the store is volatile.
Declaration
public string Path { get; }
Property Value
Type | Description |
---|---|
String |
Methods
View SourceDispose()
Closes the store.
Declaration
public override void Dispose()
Overrides
View SourceWrite<T>(Emitter<T>, String, DeliveryPolicy<T>)
Writes the specified stream to this multi-stream store.
Declaration
public void Write<T>(Emitter<T> source, string name, DeliveryPolicy<T> deliveryPolicy = null)
Parameters
Type | Name | Description |
---|---|---|
Emitter<T> | source | The source stream to write. |
String | name | The name of the persisted stream. |
DeliveryPolicy<T> | deliveryPolicy | An optional delivery policy. |
Type Parameters
Name | Description |
---|---|
T | The type of messages in the stream. |