Package com.google.common.io

Examples of com.google.common.io.Closer.register()

39
40
41
42
43
44
45
46
47
48
49
      OutputStream syserr = new BufferedOutputStream(new FileOutputStream(new File(inputFile.getAbsolutePath() + ".syserr")));
      closer.register(syserr);

      InputStream is = new BufferedInputStream(new FileInputStream(inputFile));
      closer.register(is);
      JsonReader input = new JsonReader(new InputStreamReader(is, Charsets.UTF_8));
      input.setLenient(true);

      JsonToken peek;
      while (true) {
View Full Code Here
1432
1433
1434
1435
1436
1437
1438
1439
1440
1441
1442
        slave.end = System.currentTimeMillis();
      }     
    });

    Closer closer = Closer.create();
    closer.register(eventStream);
    closer.register(w);
    try {
      OutputStream sysout = closer.register(new BufferedOutputStream(new FileOutputStream(sysoutFile)));
      OutputStream syserr = closer.register(new BufferedOutputStream(new FileOutputStream(syserrFile)));
      RandomAccessFile streamsBuffer = closer.register(new RandomAccessFile(streamsBufferFile, "rw"));
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
          + "), refusing to load it.");
    }
    Closer closer = Closer.create();
    try {
      final BufferedReader reader =
          closer.register(new BufferedReader(new InputStreamReader(file.getInputStream(), CHARSET)));
      final ArrayList<String> entries = new ArrayList<String>();
      String line = reader.readLine();
      if (!MAGIC.equals(line) && !LEGACY_MAGIC.equals(line) && !UNSUPPORTED.equals(line)) {
        throw new InvalidInputException("Prefix file does not start with expected \"" + MAGIC
            + "\" header, refusing to load the file.");
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
    File tempFile = File.createTempFile("myrrix-", ".csv.gz");
    tempFile.deleteOnExit();
    log.debug("Translating ingest input to {}", tempFile);
    Closer closer = Closer.create();
    try {
      BufferedReader buffered = closer.register(IOUtils.buffer(reader));     
      Writer out = closer.register(IOUtils.buildGZIPWriter(tempFile));
      CharSequence line;
      while ((line = buffered.readLine()) != null) {
        Iterator<String> it = COMMA_SPLIT.split(line).iterator();
        String userIDString = it.next();
View Full Code Here
318
319
320
321
322
323
324
325
326
327
328
    tempFile.deleteOnExit();
    log.debug("Translating ingest input to {}", tempFile);
    Closer closer = Closer.create();
    try {
      BufferedReader buffered = closer.register(IOUtils.buffer(reader));     
      Writer out = closer.register(IOUtils.buildGZIPWriter(tempFile));
      CharSequence line;
      while ((line = buffered.readLine()) != null) {
        Iterator<String> it = COMMA_SPLIT.split(line).iterator();
        String userIDString = it.next();
        String itemIDString = it.next();
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
            } catch (URISyntaxException e) {
                uri = new File(styleRef).toURI();
            }

            final ClientHttpRequest request = clientHttpRequestFactory.createRequest(uri, HttpMethod.GET);
            final ClientHttpResponse response = closer.register(request.execute());
            statusCode = response.getStatusCode();
            input = ByteStreams.toByteArray(response.getBody());
        } catch (Exception e) {
            return Optional.absent();
        } finally {
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
                            geotiffFile = File.createTempFile("downloadedGeotiff", ".tiff");
                            Closer closer = Closer.create();

                            try {
                                final ClientHttpRequest request = requestFactory.createRequest(url.toURI(), HttpMethod.GET);
                                final ClientHttpResponse httpResponse = closer.register(request.execute());
                                FileOutputStream output = closer.register(new FileOutputStream(geotiffFile));
                                ByteStreams.copy(httpResponse.getBody(), output);
                            } finally {
                                closer.close();
                            }
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
                            Closer closer = Closer.create();

                            try {
                                final ClientHttpRequest request = requestFactory.createRequest(url.toURI(), HttpMethod.GET);
                                final ClientHttpResponse httpResponse = closer.register(request.execute());
                                FileOutputStream output = closer.register(new FileOutputStream(geotiffFile));
                                ByteStreams.copy(httpResponse.getBody(), output);
                            } finally {
                                closer.close();
                            }
                        }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
        Closer closer = Closer.create();
        try {
            Reader input;
            if (url.getProtocol().equalsIgnoreCase("file")) {
                final CharSource charSource = Files.asCharSource(new File(url.getFile()), Constants.DEFAULT_CHARSET);
                input = closer.register(charSource.openBufferedStream());
            } else {
                final ClientHttpResponse response = closer.register(this.httpRequestFactory.createRequest(url.toURI(),
                        HttpMethod.GET).execute());

                input = closer.register(new BufferedReader(new InputStreamReader(response.getBody(), Constants.DEFAULT_CHARSET)));
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
            Reader input;
            if (url.getProtocol().equalsIgnoreCase("file")) {
                final CharSource charSource = Files.asCharSource(new File(url.getFile()), Constants.DEFAULT_CHARSET);
                input = closer.register(charSource.openBufferedStream());
            } else {
                final ClientHttpResponse response = closer.register(this.httpRequestFactory.createRequest(url.toURI(),
                        HttpMethod.GET).execute());

                input = closer.register(new BufferedReader(new InputStreamReader(response.getBody(), Constants.DEFAULT_CHARSET)));
            }
            geojsonString = CharStreams.toString(input);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.