-
Notifications
You must be signed in to change notification settings - Fork 34
Open
Description
RiakClient.Models.MapReduce.Inputs.RiakBucketInput should include the bucket type when creating the pb fragment.
This seems to work.
public override JsonWriter WriteJson(JsonWriter writer)
{
if (Filters.Count > 0)
{
writer.WritePropertyName("inputs");
writer.WriteStartObject();
WriteBucketKeyBucketJson(writer, type, bucket);
writer.WritePropertyName("key_filters");
writer.WriteStartArray();
Filters.ForEach(f => writer.WriteRawValue(f.ToJsonString()));
writer.WriteEndArray();
writer.WriteEndObject();
}
else
{
writer.WritePropertyName("inputs");
if (!string.IsNullOrEmpty(type))
{
writer.WriteStartArray();
writer.WriteValue(type);
writer.WriteValue(bucket);
writer.WriteEndArray();
}
else
{
writer.WriteValue(bucket);
}
}
return writer;
}
Metadata
Metadata
Assignees
Labels
No labels