Skip to content

Commit

Permalink
Merge remote-tracking branch 'remotes/simon/NIFI-1833' into NIFI-1833
Browse files Browse the repository at this point in the history
Made some dependency changes, tested List/FetchAzureBlob with NiFi 1.2.0-SNAPSHOT
  • Loading branch information
aperepel committed Jan 30, 2017
1 parent e9c11a7 commit fa7063e
Showing 1 changed file with 11 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,10 @@
import java.util.Collections;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.concurrent.TimeUnit;

Expand Down Expand Up @@ -92,6 +94,9 @@ public class ListAzureBlobStorage extends AbstractProcessor {
.description("All FlowFiles that are received are routed to success")
.build();

public static final Set<Relationship> relationships = Collections.unmodifiableSet(
new HashSet<>(Collections.singletonList(REL_SUCCESS)));

public static final List<PropertyDescriptor> properties = Collections.unmodifiableList(Arrays.asList(AzureConstants.ACCOUNT_NAME, AzureConstants.ACCOUNT_KEY, AzureConstants.CONTAINER, PREFIX));

@Override
Expand All @@ -111,7 +116,12 @@ public void onPropertyModified(final PropertyDescriptor descriptor, final String
public void onPrimaryNodeChange(final PrimaryNodeState newState) {
justElectedPrimaryNode = (newState == PrimaryNodeState.ELECTED_PRIMARY_NODE);
}


@Override
public Set<Relationship> getRelationships() {
return relationships;
}

@OnScheduled
public final void updateState(final ProcessContext context) throws IOException {
// Check if state already exists for this path. If so, we have already migrated the state.
Expand Down

0 comments on commit fa7063e

Please sign in to comment.