Package com.asakusafw.bulkloader.transfer

Examples of com.asakusafw.bulkloader.transfer.FileProtocol

154
155
156
157
158
159
160
161
162
163
164
                        model.__tgc__DataModelVersion());

                FileProtocol.Kind kind = startTimestamp == null
                    ? FileProtocol.Kind.CREATE_CACHE
                    : FileProtocol.Kind.UPDATE_CACHE;
                FileProtocol protocol = new FileProtocol(kind, tableInfo.getDfsFilePath(), nextRemoteInfo);
                tableInfo.setImportProtocol(protocol);
            }
            succeed = true;
        } finally {
            if (succeed == false) {
View Full Code Here
297
298
299
300
301
302
303
304
    private void setContentProtocol(String tableName, ImportTargetTableBean table) {
        assert tableName != null;
        assert table != null;
        String remoteLocation = FileNameUtil.createSendImportFileName(tableName);
        FileProtocol protocol = new FileProtocol(FileProtocol.Kind.CONTENT, remoteLocation, null);
        table.setImportProtocol(protocol);
    }
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
                    for (String tableName : bean.getImportTargetTableList()) {
                        ImportTargetTableBean table = bean.getTargetTable(tableName);
                        if (table.getCacheId() == null || table.getDfsFilePath() == null) {
                            continue;
                        }
                        FileProtocol protocol = new FileProtocol(
                                FileProtocol.Kind.GET_CACHE_INFO,
                                table.getDfsFilePath(),
                                null);

                        // send only header
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
            public Map<String, CacheInfo> call() throws IOException {
                Map<String, CacheInfo> results = new HashMap<String, CacheInfo>();
                FileList.Reader reader = provider.openReader();
                try {
                    while (reader.next()) {
                        FileProtocol protocol = reader.getCurrentProtocol();

                        // receive only header
                        reader.openContent().close();

                        if (protocol.getKind() == FileProtocol.Kind.RESPONSE_CACHE_INFO) {
                            assert protocol.getInfo() != null;
                            results.put(protocol.getLocation(), protocol.getInfo());
                        } else if (protocol.getKind() != FileProtocol.Kind.RESPONSE_NOT_FOUND
                                && protocol.getKind() != FileProtocol.Kind.RESPONSE_ERROR) {
                            throw new IOException(MessageFormat.format(
                                    "Unknown protocol in response: {0}",
                                    protocol));
                        }
                    }
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
        byte[] buf = new byte[buffSize];
        long dumpFileSize = 0;
        try {
            InputStream input = new FileInputStream(localFile);
            try {
                FileProtocol protocol = targetTable.getImportProtocol();
                assert protocol != null;
                OutputStream output = writer.openNext(protocol);
                try {
                    while (true) {
                        int read = input.read(buf);
View Full Code Here
TOP

Related Classes of com.asakusafw.bulkloader.transfer.FileProtocol

  • com.asakusafw.bulkloader.cache.DeleteCacheStorageLocal
  • com.asakusafw.bulkloader.cache.DeleteCacheStorageRemote
  • com.asakusafw.bulkloader.cache.DeleteCacheStorageRemoteTest
  • com.asakusafw.bulkloader.cache.GetCacheInfoLocal
  • com.asakusafw.bulkloader.cache.GetCacheInfoRemote
  • com.asakusafw.bulkloader.cache.GetCacheInfoRemoteTest
  • com.asakusafw.bulkloader.exporter.ExportFileReceive
  • com.asakusafw.bulkloader.extractor.DfsFileImport
  • com.asakusafw.bulkloader.extractor.DfsFileImportTest
  • com.asakusafw.bulkloader.importer.ImportFileSend
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.