http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.class new file mode 100644 index 0000000..d7c093f Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.class differ
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO$Formatter.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO$Formatter.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO$Formatter.class new file mode 100644 index 0000000..ea2ea48 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO$Formatter.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.class new file mode 100644 index 0000000..51fc897 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.class new file mode 100644 index 0000000..edebe8e Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.class new file mode 100644 index 0000000..e25a3f2 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.class new file mode 100644 index 0000000..354d6d3 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.class new file mode 100644 index 0000000..241625a Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.class new file mode 100644 index 0000000..398bb9b Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.class new file mode 100644 index 0000000..5a39b6f Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.class new file mode 100644 index 0000000..990dcaf Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.class new file mode 100644 index 0000000..3ca7f1e Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.class new file mode 100644 index 0000000..6411749 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.class new file mode 100644 index 0000000..6422776 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.class new file mode 100644 index 0000000..9632ba5 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.class new file mode 100644 index 0000000..a007034 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.class new file mode 100644 index 0000000..81f90f8 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterPortStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterPortStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterPortStatusEntity.class new file mode 100644 index 0000000..0191736 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterPortStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterProcessorStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterProcessorStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterProcessorStatusEntity.class new file mode 100644 index 0000000..66278be Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterProcessorStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterRemoteProcessGroupStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterRemoteProcessGroupStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterRemoteProcessGroupStatusEntity.class new file mode 100644 index 0000000..717bd5d Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterRemoteProcessGroupStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterSearchResultsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterSearchResultsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterSearchResultsEntity.class new file mode 100644 index 0000000..826b456 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterSearchResultsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusEntity.class new file mode 100644 index 0000000..fd8b930 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusHistoryEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusHistoryEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusHistoryEntity.class new file mode 100644 index 0000000..d5b2b04 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ClusterStatusHistoryEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.class new file mode 100644 index 0000000..217ab8b Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionsEntity.class new file mode 100644 index 0000000..88dc8e5 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ConnectionsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.class new file mode 100644 index 0000000..e6d4a4d Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerConfigurationEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerEntity.class new file mode 100644 index 0000000..4b7c464 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerStatusEntity.class new file mode 100644 index 0000000..a2c1774 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ControllerStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CounterEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CounterEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CounterEntity.class new file mode 100644 index 0000000..78348ca Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CounterEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CountersEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CountersEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CountersEntity.class new file mode 100644 index 0000000..00cd50a Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/CountersEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/Entity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/Entity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/Entity.class new file mode 100644 index 0000000..e0786bc Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/Entity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FlowSnippetEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FlowSnippetEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FlowSnippetEntity.class new file mode 100644 index 0000000..64426df Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FlowSnippetEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.class new file mode 100644 index 0000000..c02c5d4 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelsEntity.class new file mode 100644 index 0000000..3558037 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/FunnelsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/HistoryEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/HistoryEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/HistoryEntity.class new file mode 100644 index 0000000..e64fe58 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/HistoryEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortEntity.class new file mode 100644 index 0000000..89779b7 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortsEntity.class new file mode 100644 index 0000000..a4a536f Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/InputPortsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.class new file mode 100644 index 0000000..567191d Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelsEntity.class new file mode 100644 index 0000000..0bbf4d5 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LabelsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LineageEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LineageEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LineageEntity.class new file mode 100644 index 0000000..6f6a8e4 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/LineageEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeEntity.class new file mode 100644 index 0000000..af254bd Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeStatusEntity.class new file mode 100644 index 0000000..3cd8f78 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeSystemDiagnosticsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeSystemDiagnosticsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeSystemDiagnosticsEntity.class new file mode 100644 index 0000000..a72f158 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/NodeSystemDiagnosticsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortEntity.class new file mode 100644 index 0000000..eb7872c Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortsEntity.class new file mode 100644 index 0000000..2459f06 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/OutputPortsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/PrioritizerTypesEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/PrioritizerTypesEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/PrioritizerTypesEntity.class new file mode 100644 index 0000000..d2bbd17 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/PrioritizerTypesEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupEntity.class new file mode 100644 index 0000000..ea1bf33 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupStatusEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupStatusEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupStatusEntity.class new file mode 100644 index 0000000..6e6d3f6 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupStatusEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupsEntity.class new file mode 100644 index 0000000..8cc8f3e Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessGroupsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.class new file mode 100644 index 0000000..7040fc5 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorHistoryEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorHistoryEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorHistoryEntity.class new file mode 100644 index 0000000..fda40d9 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorHistoryEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorTypesEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorTypesEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorTypesEntity.class new file mode 100644 index 0000000..2ccda7e Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorTypesEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorsEntity.class new file mode 100644 index 0000000..e8e12e3 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProcessorsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEntity.class new file mode 100644 index 0000000..cec6043 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEventEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEventEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEventEntity.class new file mode 100644 index 0000000..3fefd86 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceEventEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceOptionsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceOptionsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceOptionsEntity.class new file mode 100644 index 0000000..e7f7a26 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/ProvenanceOptionsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.class new file mode 100644 index 0000000..fa6a8fc Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupPortEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupPortEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupPortEntity.class new file mode 100644 index 0000000..da9489c Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupPortEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupsEntity.class new file mode 100644 index 0000000..bcd987c Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/RemoteProcessGroupsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SearchResultsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SearchResultsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SearchResultsEntity.class new file mode 100644 index 0000000..337b7d6 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SearchResultsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SnippetEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SnippetEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SnippetEntity.class new file mode 100644 index 0000000..5c67d8e Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SnippetEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/StatusHistoryEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/StatusHistoryEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/StatusHistoryEntity.class new file mode 100644 index 0000000..71a0441 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/StatusHistoryEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SystemDiagnosticsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SystemDiagnosticsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SystemDiagnosticsEntity.class new file mode 100644 index 0000000..76ee09a Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/SystemDiagnosticsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplateEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplateEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplateEntity.class new file mode 100644 index 0000000..4d50806 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplateEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplatesEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplatesEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplatesEntity.class new file mode 100644 index 0000000..b76751f Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/TemplatesEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserEntity.class new file mode 100644 index 0000000..4fe06b5 Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.class new file mode 100644 index 0000000..4df503c Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserGroupEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserSearchResultsEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserSearchResultsEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserSearchResultsEntity.class new file mode 100644 index 0000000..4e95aae Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UserSearchResultsEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UsersEntity.class ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UsersEntity.class b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UsersEntity.class new file mode 100644 index 0000000..d58f42a Binary files /dev/null and b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/bin/src/main/java/org/apache/nifi/web/api/entity/UsersEntity.class differ http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java index 7cb2874..54f0807 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java @@ -48,6 +48,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; import javax.net.ssl.SSLContext; +import org.apache.commons.lang3.StringUtils; import org.apache.nifi.admin.service.UserService; import org.apache.nifi.annotation.lifecycle.OnAdded; import org.apache.nifi.annotation.lifecycle.OnRemoved; @@ -128,14 +129,12 @@ import org.apache.nifi.groups.ProcessGroup; import org.apache.nifi.groups.RemoteProcessGroup; import org.apache.nifi.groups.RemoteProcessGroupPortDescriptor; import org.apache.nifi.groups.StandardProcessGroup; -import org.apache.nifi.stream.io.StreamUtils; import org.apache.nifi.logging.LogLevel; import org.apache.nifi.logging.LogRepository; import org.apache.nifi.logging.LogRepositoryFactory; import org.apache.nifi.logging.ProcessorLog; import org.apache.nifi.logging.ProcessorLogObserver; import org.apache.nifi.nar.ExtensionManager; -import org.apache.nifi.nar.NarClassLoader; import org.apache.nifi.nar.NarCloseable; import org.apache.nifi.nar.NarThreadContextClassLoader; import org.apache.nifi.processor.Processor; @@ -165,6 +164,7 @@ import org.apache.nifi.reporting.EventAccess; import org.apache.nifi.reporting.ReportingTask; import org.apache.nifi.reporting.Severity; import org.apache.nifi.scheduling.SchedulingStrategy; +import org.apache.nifi.stream.io.StreamUtils; import org.apache.nifi.util.FormatUtils; import org.apache.nifi.util.NiFiProperties; import org.apache.nifi.util.ReflectionUtils; @@ -184,7 +184,6 @@ import org.apache.nifi.web.api.dto.RemoteProcessGroupDTO; import org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO; import org.apache.nifi.web.api.dto.TemplateDTO; import org.apache.nifi.web.api.dto.status.StatusHistoryDTO; -import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-resources/src/main/resources/conf/nifi.properties ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-resources/src/main/resources/conf/nifi.properties b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-resources/src/main/resources/conf/nifi.properties index fa55623..fcbfe46 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-resources/src/main/resources/conf/nifi.properties +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-resources/src/main/resources/conf/nifi.properties @@ -62,8 +62,17 @@ nifi.content.repository.always.sync=${nifi.content.repository.always.sync} nifi.content.viewer.url=${nifi.content.viewer.url} # Provenance Repository Properties +# Choose implementation of Provenance Repository nifi.provenance.repository.implementation=${nifi.provenance.repository.implementation} +# For "Persistent Provenance Repository" +#nifi.provenance.repository.implementation=org.apache.nifi.provenance.PersistentProvenanceRepository +# For in-memory provenance repository +#nifi.provenance.repository.implementation=org.apache.nifi.provenance.VolatileProvenanceRepository +# For "Journaling Provenance Repository" +#nifi.provenance.repository.implementation=org.apache.nifi.provenance.journaling.JournalingProvenanceRepository + + # Persistent Provenance Repository Properties nifi.provenance.repository.directory.default=${nifi.provenance.repository.directory.default} nifi.provenance.repository.max.storage.time=${nifi.provenance.repository.max.storage.time} @@ -83,9 +92,35 @@ nifi.provenance.repository.indexed.attributes=${nifi.provenance.repository.index # but should provide better performance nifi.provenance.repository.index.shard.size=${nifi.provenance.repository.index.shard.size} + + # Volatile Provenance Respository Properties nifi.provenance.repository.buffer.size=${nifi.provenance.repository.buffer.size} + + +# Journaling Provenance Repository Properties +#nifi.provenance.repository.directory.default=${nifi.provenance.repository.directory.default} +#nifi.provenance.repository.max.storage.time=${nifi.provenance.repository.max.storage.time} +#nifi.provenance.repository.max.storage.size=${nifi.provenance.repository.max.storage.size} +#nifi.provenance.repository.rollover.time=${nifi.provenance.repository.rollover.time} +#nifi.provenance.repository.rollover.size=${nifi.provenance.repository.rollover.size} +#nifi.provenance.repository.compress.on.rollover=${nifi.provenance.repository.compress.on.rollover} +#nifi.provenance.repository.always.sync=${nifi.provenance.repository.always.sync} +#nifi.provenance.repository.journal.count=${nifi.provenance.repository.journal.count} +# Comma-separated list of fields. Fields that are not indexed will not be searchable. Valid fields are: +# EventType, FlowFileUUID, Filename, TransitURI, ProcessorID, AlternateIdentifierURI, ContentType, Relationship, Details +#nifi.provenance.repository.indexed.fields=${nifi.provenance.repository.indexed.fields} +# FlowFile Attributes that should be indexed and made searchable +#nifi.provenance.repository.indexed.attributes=${nifi.provenance.repository.indexed.attributes} +# Larger values for block size will result in better compression but slower read performance +#nifi.provenance.repository.writer.block.size=5000 +#nifi.provenance.repository.worker.threads=2 +#nifi.provenance.repository.query.threads=${nifi.provenance.repository.query.threads} +#nifi.provenance.repository.compression.threads=2 + + + # Component Status Repository nifi.components.status.repository.implementation=${nifi.components.status.repository.implementation} nifi.components.status.repository.buffer.size=${nifi.components.status.repository.buffer.size} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournaledStorageLocation.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournaledStorageLocation.java b/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournaledStorageLocation.java index cdb98c8..d4f9e44 100644 --- a/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournaledStorageLocation.java +++ b/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournaledStorageLocation.java @@ -23,11 +23,11 @@ import org.apache.nifi.provenance.StorageLocation; public class JournaledStorageLocation implements StorageLocation, Comparable<JournaledStorageLocation>, Comparator<JournaledStorageLocation> { private final String containerName; private final String sectionName; - private final String journalId; + private final Long journalId; private final int blockIndex; private final long eventId; - public JournaledStorageLocation(final String containerName, final String sectionName, final String journalId, final int blockIndex, final long eventId) { + public JournaledStorageLocation(final String containerName, final String sectionName, final Long journalId, final int blockIndex, final long eventId) { this.containerName = containerName; this.sectionName = sectionName; this.journalId = journalId; @@ -43,7 +43,7 @@ public class JournaledStorageLocation implements StorageLocation, Comparable<Jou return sectionName; } - public String getJournalId() { + public Long getJournalId() { return journalId; } @@ -56,6 +56,11 @@ public class JournaledStorageLocation implements StorageLocation, Comparable<Jou } @Override + public String toString() { + return "JournaledStorageLocation [containerName=" + containerName + ", sectionName=" + sectionName + ", journalId=" + journalId + ", eventId=" + eventId + "]"; + } + + @Override public int compare(final JournaledStorageLocation o1, final JournaledStorageLocation o2) { final int containerVal = o1.getContainerName().compareTo(o2.getContainerName()); if ( containerVal != 0 ) { http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f23f36d7/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournalingProvenanceRepository.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournalingProvenanceRepository.java b/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournalingProvenanceRepository.java index cc97ee9..0aa20df 100644 --- a/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournalingProvenanceRepository.java +++ b/nifi/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-journaling-provenance-repository/src/main/java/org/apache/nifi/provenance/journaling/JournalingProvenanceRepository.java @@ -30,11 +30,13 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.apache.nifi.events.EventReporter; @@ -48,6 +50,8 @@ import org.apache.nifi.provenance.StandardProvenanceEventRecord; import org.apache.nifi.provenance.StorageLocation; import org.apache.nifi.provenance.StoredProvenanceEvent; import org.apache.nifi.provenance.journaling.config.JournalingRepositoryConfig; +import org.apache.nifi.provenance.journaling.index.EventIndexSearcher; +import org.apache.nifi.provenance.journaling.index.IndexAction; import org.apache.nifi.provenance.journaling.index.IndexManager; import org.apache.nifi.provenance.journaling.index.LuceneIndexManager; import org.apache.nifi.provenance.journaling.index.QueryUtils; @@ -66,24 +70,36 @@ import org.apache.nifi.provenance.lineage.ComputeLineageSubmission; import org.apache.nifi.provenance.search.Query; import org.apache.nifi.provenance.search.QuerySubmission; import org.apache.nifi.provenance.search.SearchableField; +import org.apache.nifi.reporting.Severity; import org.apache.nifi.util.FormatUtils; import org.apache.nifi.util.NiFiProperties; import org.slf4j.Logger; import org.slf4j.LoggerFactory; + +// TODO: Add header info to journals. Magic header. Prov repo implementation. Version. Encoding. Encoding Version. +// TODO: EXPIRE : backpressure if unable to delete fast enough! I.e., if size is greater than 110% of size specified +// TODO: Ensure number of partitions does not go below the current value. If it does, use the existing value +// so that we don't lose events. public class JournalingProvenanceRepository implements ProvenanceEventRepository { - public static final String BLOCK_SIZE = "nifi.provenance.block.size"; + public static final String WORKER_THREAD_POOL_SIZE = "nifi.provenance.repository.worker.threads"; + public static final String BLOCK_SIZE = "nifi.provenance.repository.writer.block.size"; private static final Logger logger = LoggerFactory.getLogger(JournalingProvenanceRepository.class); private final JournalingRepositoryConfig config; private final AtomicLong idGenerator = new AtomicLong(0L); - private final ScheduledExecutorService executor; - private EventReporter eventReporter; // effectively final - private PartitionManager partitionManager; // effectively final - private QueryManager queryManager; // effectively final - private IndexManager indexManager; // effectively final + // the follow member variables are effectively final. They are initialized + // in the initialize method rather than the constructor because we want to ensure + // that they only not created every time that the Java Service Loader instantiates the class. + private ScheduledExecutorService workerExecutor; + private ExecutorService queryExecutor; + private ExecutorService compressionExecutor; + private EventReporter eventReporter; + private PartitionManager partitionManager; + private QueryManager queryManager; + private IndexManager indexManager; public JournalingProvenanceRepository() throws IOException { this(createConfig()); @@ -91,19 +107,22 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository public JournalingProvenanceRepository(final JournalingRepositoryConfig config) throws IOException { this.config = config; - this.executor = Executors.newScheduledThreadPool(config.getThreadPoolSize(), new ThreadFactory() { - private final ThreadFactory defaultFactory = Executors.defaultThreadFactory(); - + } + + private static ThreadFactory createThreadFactory(final String namePrefix) { + final ThreadFactory defaultFactory = Executors.defaultThreadFactory(); + final AtomicInteger counter = new AtomicInteger(0); + + return new ThreadFactory() { @Override public Thread newThread(final Runnable r) { final Thread thread = defaultFactory.newThread(r); - thread.setName("Provenance Repository Worker Thread"); + thread.setName(namePrefix + "-" + counter.incrementAndGet()); return thread; } - }); + }; } - private static JournalingRepositoryConfig createConfig() { final NiFiProperties properties = NiFiProperties.getInstance(); final Map<String, Path> storageDirectories = properties.getProvenanceRepositoryPaths(); @@ -116,6 +135,7 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository final String rolloverSize = properties.getProperty(NiFiProperties.PROVENANCE_ROLLOVER_SIZE, "100 MB"); final String shardSize = properties.getProperty(NiFiProperties.PROVENANCE_INDEX_SHARD_SIZE, "500 MB"); final int queryThreads = properties.getIntegerProperty(NiFiProperties.PROVENANCE_QUERY_THREAD_POOL_SIZE, 2); + final int workerThreads = properties.getIntegerProperty(WORKER_THREAD_POOL_SIZE, 4); final int journalCount = properties.getIntegerProperty(NiFiProperties.PROVENANCE_JOURNAL_COUNT, 16); final long storageMillis = FormatUtils.getTimeDuration(storageTime, TimeUnit.MILLISECONDS); @@ -126,7 +146,7 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository final boolean compressOnRollover = Boolean.parseBoolean(properties.getProperty(NiFiProperties.PROVENANCE_COMPRESS_ON_ROLLOVER)); final String indexedFieldString = properties.getProperty(NiFiProperties.PROVENANCE_INDEXED_FIELDS); final String indexedAttrString = properties.getProperty(NiFiProperties.PROVENANCE_INDEXED_ATTRIBUTES); - final int blockSize = properties.getIntegerProperty(BLOCK_SIZE, 1000); + final int blockSize = properties.getIntegerProperty(BLOCK_SIZE, 5000); final Boolean alwaysSync = Boolean.parseBoolean(properties.getProperty("nifi.provenance.repository.always.sync", "false")); @@ -152,7 +172,8 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository config.setJournalRolloverPeriod(rolloverMillis, TimeUnit.MILLISECONDS); config.setEventExpiration(storageMillis, TimeUnit.MILLISECONDS); config.setMaxStorageCapacity(maxStorageBytes); - config.setThreadPoolSize(queryThreads); + config.setQueryThreadPoolSize(queryThreads); + config.setWorkerThreadPoolSize(workerThreads); config.setPartitionCount(journalCount); config.setBlockSize(blockSize); @@ -169,9 +190,43 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository public synchronized void initialize(final EventReporter eventReporter) throws IOException { this.eventReporter = eventReporter; - this.indexManager = new LuceneIndexManager(config, executor); - this.partitionManager = new QueuingPartitionManager(indexManager, config, executor); - this.queryManager = new StandardQueryManager(partitionManager, config, 10); + // We use 3 different thread pools here because we don't want to threads from 1 pool to interfere with + // each other. This is because the worker threads can be long running, and they shouldn't tie up the + // compression threads. Likewise, there may be MANY compression tasks, which could delay the worker + // threads. And the query threads need to run immediately when a user submits a query - they cannot + // wait until we finish compressing data and sync'ing the repository! + final int workerThreadPoolSize = Math.max(2, config.getWorkerThreadPoolSize()); + this.workerExecutor = Executors.newScheduledThreadPool(workerThreadPoolSize, createThreadFactory("Provenance Repository Worker Thread")); + + final int queryThreadPoolSize = Math.max(2, config.getQueryThreadPoolSize()); + this.queryExecutor = Executors.newScheduledThreadPool(queryThreadPoolSize, createThreadFactory("Provenance Repository Query Thread")); + + final int compressionThreads = Math.max(1, config.getCompressionThreadPoolSize()); + this.compressionExecutor = Executors.newFixedThreadPool(compressionThreads, createThreadFactory("Provenance Repository Compression Thread")); + + this.indexManager = new LuceneIndexManager(config, workerExecutor, queryExecutor); + this.partitionManager = new QueuingPartitionManager(indexManager, idGenerator, config, workerExecutor, compressionExecutor); + this.queryManager = new StandardQueryManager(indexManager, queryExecutor, config, 10); + + final Long maxEventId = getMaxEventId(); + if ( maxEventId != null && maxEventId > 0 ) { + this.idGenerator.set(maxEventId); // maxEventId returns 1 greater than the last event id written + } + + // the partition manager may have caused journals to be re-indexed. We will sync the + // index manager to make sure that we are completely in sync before allowing any new data + // to be written to the repo. + indexManager.sync(); + + final long expirationFrequencyNanos = config.getExpirationFrequency(TimeUnit.NANOSECONDS); + workerExecutor.scheduleWithFixedDelay(new ExpireOldEvents(), expirationFrequencyNanos, expirationFrequencyNanos, TimeUnit.NANOSECONDS); + + workerExecutor.scheduleWithFixedDelay(new Runnable() { + @Override + public void run() { + partitionManager.deleteEventsBasedOnSize(); + } + }, expirationFrequencyNanos, expirationFrequencyNanos, TimeUnit.NANOSECONDS); } @Override @@ -186,12 +241,19 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository @Override public void registerEvents(final Collection<ProvenanceEventRecord> events) throws IOException { - partitionManager.withPartition(new VoidPartitionAction() { - @Override - public void perform(final Partition partition) throws IOException { - partition.registerEvents(events, idGenerator.getAndAdd(events.size())); + try { + partitionManager.withPartition(new VoidPartitionAction() { + @Override + public void perform(final Partition partition) throws IOException { + partition.registerEvents(events, idGenerator.getAndAdd(events.size())); + } + }, true); + } catch (final IOException ioe) { + if ( eventReporter != null ) { + eventReporter.reportEvent(Severity.ERROR, "Provenance Repository", "Failed to persist " + events.size() + " events to Provenance Repository due to " + ioe); } - }, true); + throw ioe; + } } @Override @@ -216,11 +278,11 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository public List<StoredProvenanceEvent> getEvents(final long firstRecordId, final int maxRecords) throws IOException { // Must generate query to determine the appropriate StorageLocation objects and then call // getEvent(List<StorageLocation>) - final Set<List<JournaledStorageLocation>> resultSet = partitionManager.withEachPartition( - new PartitionAction<List<JournaledStorageLocation>>() { + final Set<List<JournaledStorageLocation>> resultSet = indexManager.withEachIndex( + new IndexAction<List<JournaledStorageLocation>>() { @Override - public List<JournaledStorageLocation> perform(final Partition partition) throws IOException { - return partition.getEvents(firstRecordId, maxRecords); + public List<JournaledStorageLocation> perform(final EventIndexSearcher searcher) throws IOException { + return searcher.getEvents(firstRecordId, maxRecords); } }); @@ -267,7 +329,12 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository final Callable<List<StoredProvenanceEvent>> callable = new Callable<List<StoredProvenanceEvent>>() { @Override public List<StoredProvenanceEvent> call() throws Exception { - try(final TocReader tocReader = new StandardTocReader(new File(journalFile.getParentFile(), journalFile.getName() + ".toc")); + final File tocFile = QueryUtils.getTocFile(journalFile); + if ( !journalFile.exists() || !tocFile.exists() ) { + return Collections.emptyList(); + } + + try(final TocReader tocReader = new StandardTocReader(tocFile); final JournalReader reader = new StandardJournalReader(journalFile)) { final List<StoredProvenanceEvent> storedEvents = new ArrayList<>(locationsForFile.size()); @@ -284,7 +351,7 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository } }; - final Future<List<StoredProvenanceEvent>> future = executor.submit(callable); + final Future<List<StoredProvenanceEvent>> future = queryExecutor.submit(callable); futures.add(future); } @@ -331,7 +398,7 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository public Long perform(final Partition partition) throws IOException { return partition.getMaxEventId(); } - }); + }, false); Long maxId = null; for ( final Long id : maxIds ) { @@ -360,26 +427,22 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository @Override public ComputeLineageSubmission submitLineageComputation(final String flowFileUuid) { - // TODO Auto-generated method stub - return null; + return queryManager.submitLineageComputation(flowFileUuid); } @Override public ComputeLineageSubmission retrieveLineageSubmission(final String lineageIdentifier) { - // TODO Auto-generated method stub - return null; + return queryManager.retrieveLineageSubmission(lineageIdentifier); } @Override public ComputeLineageSubmission submitExpandParents(final long eventId) { - // TODO Auto-generated method stub - return null; + return queryManager.submitExpandParents(this, eventId); } @Override public ComputeLineageSubmission submitExpandChildren(final long eventId) { - // TODO Auto-generated method stub - return null; + return queryManager.submitExpandChildren(this, eventId); } @Override @@ -388,16 +451,40 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository partitionManager.shutdown(); } - indexManager.close(); + if ( indexManager != null ) { + try { + indexManager.close(); + } catch (final IOException ioe) { + logger.warn("Failed to shutdown Index Manager due to {}", ioe.toString()); + if ( logger.isDebugEnabled() ) { + logger.warn("", ioe); + } + } + } - // TODO: make sure that all are closed here! + if ( queryManager != null ) { + try { + queryManager.close(); + } catch (final IOException ioe) { + logger.warn("Failed to shutdown Query Manager due to {}", ioe.toString()); + if ( logger.isDebugEnabled() ) { + logger.warn("", ioe); + } + } + } - executor.shutdown(); + compressionExecutor.shutdown(); + workerExecutor.shutdown(); + queryExecutor.shutdown(); } @Override public List<SearchableField> getSearchableFields() { - return config.getSearchableFields(); + final List<SearchableField> searchableFields = new ArrayList<>(config.getSearchableFields()); + // we exclude the Event Time because it is always searchable and is a bit special in its handling + // because it dictates in some cases which index files we look at + searchableFields.remove(SearchableFields.EventTime); + return searchableFields; } @Override @@ -413,7 +500,7 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository public Long perform(final Partition partition) throws IOException { return partition.getEarliestEventTime(); } - }); + }, false); // Find the latest timestamp for each of the "earliest" timestamps. // This is a bit odd, but we're doing it for a good reason: @@ -437,4 +524,43 @@ public class JournalingProvenanceRepository implements ProvenanceEventRepository return latest; } + + + private class ExpireOldEvents implements Runnable { + @Override + public void run() { + final long now = System.currentTimeMillis(); + final long expirationThreshold = now - config.getEventExpiration(TimeUnit.MILLISECONDS); + + try { + indexManager.deleteOldEvents(expirationThreshold); + } catch (final IOException ioe) { + logger.error("Failed to delete expired events from index due to {}", ioe.toString()); + if ( logger.isDebugEnabled() ) { + logger.error("", ioe); + } + } + + try { + partitionManager.withEachPartitionSerially(new VoidPartitionAction() { + @Override + public void perform(final Partition partition) throws IOException { + try { + partition.deleteOldEvents(expirationThreshold); + } catch (final IOException ioe) { + logger.error("Failed to delete expired events from Partition {} due to {}", partition, ioe.toString()); + if ( logger.isDebugEnabled() ) { + logger.error("", ioe); + } + } + } + }, false); + } catch (IOException ioe) { + logger.error("Failed to delete expired events from journals due to {}", ioe.toString()); + if ( logger.isDebugEnabled() ) { + logger.error("", ioe); + } + } + } + } }
