Sha256: ae1186ef7a238d65c9efd9d5ab4df8e1686a1d460923c4e467aedb4489e96027
Contents?: true
Size: 1.31 KB
Versions: 11
Compression:
Stored size: 1.31 KB
Contents
package org.embulk.input.zendesk.stream.paginator.sunshine;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.embulk.input.zendesk.ZendeskInputPlugin;
import org.embulk.input.zendesk.clients.ZendeskRestClient;
import org.embulk.input.zendesk.utils.ZendeskUtils;
import java.util.Iterator;
import java.util.function.Consumer;
public class UserEventSpliterator extends SunshineSpliterator
{
private String userID;
public UserEventSpliterator(final String userID, final String path, final ZendeskRestClient zendeskRestClient, final ZendeskInputPlugin.PluginTask task, final boolean isPreview)
{
super(path, zendeskRestClient, task, isPreview);
this.userID = userID;
}
@Override
protected void handleRunIterator(final Iterator<JsonNode> iterator, final Consumer<? super JsonNode> action)
{
iterator.forEachRemaining(
item -> {
if (!ZendeskUtils.isNull(item)) {
JsonNode temp = iterator.next();
// Because in the returned json doesn't have user_id, so we try to add to it
((ObjectNode) temp).put("user_id", this.userID);
action.accept(temp);
}
});
}
}
Version data entries
11 entries across 11 versions & 2 rubygems